package net.csdn.business.notify.handler.handler.impl;


import lombok.extern.slf4j.Slf4j;
import net.csdn.business.notify.common.enums.NotifyChannel;
import net.csdn.business.notify.common.pipeline.domain.TaskInfo;
import net.csdn.business.notify.handler.handler.BaseHandler;
import org.springframework.stereotype.Component;


/**
 * @ClassName ImHandler
 * @Description  站内信处理
 * @Author zhangyl
 * @Date 2023/11/30 18:23
 */
@Component
@Slf4j
public class ImHandler extends BaseHandler {

    public ImHandler() {
        channelCode = NotifyChannel.IM.getCode();
        /*Double rateInitValue = Double.valueOf(10);
        flowControlParam = FlowControlParam.builder().rateInitValue(rateInitValue)
                .rateLimitStrategy(RateLimitStrategy.REQUEST_RATE_LIMIT)
                .rateLimiter(RateLimiter.create(rateInitValue)).build();*/

    }

    @Override
    public boolean handler(TaskInfo taskInfo) {
        // TODO 后续在这里添加实时通知逻辑
        return true;
    }


}
